package com.ixion.mongo.utils;

import com.mongodb.DB;

/**
 * 数据库连接对象
 * 
 * @author 贵源<br>
 *         Create at 2014年2月23日
 */
public class DBConnection {

	public static DBConnection me() {
		return new DBConnection();
	}

	/**
	 * 获取数据库连接
	 * 
	 * @param connector
	 *            mongo连接
	 * @param dbName
	 *            数据库名称
	 * @return 数据库连接
	 */
	public DB getDbConnection(Connector connector, String dbName) {
		return connector.getDB(dbName);
	}

	/**
	 * 获取db连接并验证
	 * 
	 * @param connector
	 *            mongo连接
	 * @param dbName
	 *            数据库名称
	 * @param user
	 *            用户
	 * @param pwd
	 *            密码
	 * @return 验证的db连接对象
	 */
	@SuppressWarnings("deprecation")
	public DB getDbConnection(Connector connector, String dbName, String user, String pwd) {
		DB db = connector.getDB(dbName);
		db.authenticate(user, pwd.toCharArray());
		return db;
	}
}
